package com.cdream.basic.mq.rocket;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/mq")
public class MqController {
    @Autowired
    private RocketMqProducer rocketMqProducer;
    @RequestMapping("/test")
    public void testMq(){
        rocketMqProducer.asyncReduceStock(1,2);
    }
}
